package com.qfjy.service.impl.example3;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

/**
 * @ClassName WeatherServiceImpl
 * @Description TODO  天气预报分发
 * @Author guoweixin
 * @Date 2023/4/13
 * @Version 1.0
 */
@Service
@Slf4j
public class WeatherServiceImpl {

    @RabbitListener(queues = {"tbFanoutQueue"})
    public void taobaoWeatherInfo(String msg){

        log.info("淘宝显示的天气预报信息：{}",msg);

    }


    @RabbitListener(queues = {"jdFanoutQueue"})
    public void jdWeatherInfo(String msg){

        log.info("京东显示的天气预报信息：{}",msg);

    }

}
